# -*- coding: utf-8 -*-

from airflow.providers.apache.hdfs.sensors.web_hdfs import WebHdfsSensor

from datetime import timedelta


jms_dm_oms__dim_sales_price_base = WebHdfsSensor(
    pool='unlimited_pool',
    task_id="jms_dm_oms__dim_sales_price_base",
    filepath='/dw/hive/spmi_dim.db/external/dim_sales_price_base/',
    execution_timeout=timedelta(minutes=15),
    email=['jarl.huang@jtexpress.com','yl_bigdata@yl-scm.com'],
    retries=2,
)